package com.demo.map;

import com.demo.domain.EventEntity;
import com.demo.util.LogToEventEntity;
import org.apache.flink.api.common.functions.MapFunction;

/**
 * @author XINZE
 */
public class EventProductMapFunction implements MapFunction<String, EventEntity> {
    @Override
    public EventEntity map(String s) throws Exception {
        EventEntity tag = LogToEventEntity.getLog(s);
        return tag;
    }
}
